3. SpringBoot使用jms聆聽MQ

此次主要介紹jmsTemplate 主動式聆聽MQ

目標：可以透過jmsTemplate聆聽MQ(接收)

前情提要：
銜接上1篇文章分析1下
之前介紹的主要是被動式透過API觸發
而馬上要介紹的，當MQ接收到Message 此專案服務會接收下來進行處理

那現在開始介紹jmsTemplate 的Linstener

必須知識：

java 8
spring系列
MVC 分層抽離
mq的基本知識
可能需要會通靈，解釋性資訊不多XD

spring boot核心應用為以下

spring starter

mq spring starter

<parent>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-parent</artifactId>
 <version>2.7.11</version>
 <relativePath/> <!-- lookup parent from repository -->
</parent>
<dependency>
 <groupId>com.ibm.mq</groupId>
 <artifactId>mq-jms-spring-boot-starter</artifactId>
 <version>2.0.0</version>
</dependency>

聆聽QUEUE設定檔
JmsListener.class

@Slf4j
@EnableJms // 上一篇為Application.class 使用到的, 因現在分層抽離分工好
@Component
public class JmsListener {

@Bean
public JmsListenerContainerFactory<?> myFactory(ConnectionFactory connectionFactory,
                                                DefaultJmsListenerContainerFactoryConfigurer configurer) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    configurer.configure(factory, connectionFactory);
    return factory;
}
}

建立一個要聆聽的MQ進入點
EntryPoint.class

@Slf4j
@Component
public class EntryPoint {

    @Autowired
    JmsMessageService jmsMessageService;

    @JmsListener(destination = "自定義佇列", containerFactory = "myFactory")
    public void receiveMessage(Message message) throws JMSException {
        log.info(jmsMessageService.getMsg(message));
    }
}

補充：

需要有mq服務建議可以使用containter方便又快速

主要是給自己的一個紀錄，也分享給有需要的夥伴
註解部分有提及一些參考的連結，有興趣可以點進去看看喔

這是一個心血來潮，產生的文章
若有喜歡或交流的部分都歡迎在下方留言，多多關照。